package com.mysteel.cyx.ddd.infrastructure.adater;


import com.mysteel.cyx.ddd.infrastructure.messaging.MessageQueue;// 假设这是Messaging层中的消息队列接口

public class MessagingQueueAdapter implements QueueAdapter {
    private final MessageQueue messageQueue;

    public MessagingQueueAdapter(MessageQueue messageQueue) {
        this.messageQueue = messageQueue;
    }

    @Override
    public void sendMessage(String message) {
        // 使用Messaging层中的消息队列接口发送消息
        messageQueue.send(message);
    }
}
